package com.arnold.demo.journal.common

import com.arnold.demo.journal.config.Config
import org.apache.spark.sql.SparkSession

/**
  * Created by arnold.zhu on 2017/7/20.
  */
object KuduUtil {

  val kuduTableName = "kudu_invoices"



  def createTable(tableName: String): Unit = {

  }

  def insert(sql: String): Unit = {
    val kuduOptions = Map("kudu.master" -> Config.KUDU_MASTER, "kudu.table" -> kuduTableName)
//    sparkSession.sql(sql)
  }


}
